package com.reisdelay.consumer;

import com.reisdelay.redis.RedisConsumer;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Component;

@Component
public class TestConsumer1 implements RedisConsumer {
    @Override
    public String getKey() {
        return "1";
    }

    @Override
    public void Consumer(Object data, ZSetOperations<String, Object> zSet) {
        System.out.println(this.getClass().getName()+"【key="+getKey()+"】===>"+data);
        zSet.remove(getKey(),data);
    }
}
